/**
* @Title: TimeClientHandler.java
* @Package com.an.timeserver
* @Description: TODO(用一句话描述该文件做什么)
* @author antch,861710865@qq.com
* @date 2017年7月20日 下午3:03:13
* @version V1.0
*/


package com.an.timeserver;

import java.sql.Date;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
* @ClassName: TimeClientHandler
* @Description: TODO(这里用一句话描述这个类的作用)
* @author antch,861710865@qq.com
* @date 2017年7月20日 下午3:03:13
*
*/

public class TimeClientHandler extends ChannelInboundHandlerAdapter {


	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		ByteBuf b = (ByteBuf) msg;
		long currentTime = (b.readUnsignedInt() - 22089888800L) * 1000L;
		System.out.println("当前时间：" + new Date(currentTime));
		ctx.close();
		b.release();
	}

	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
		cause.printStackTrace();
		ctx.close();
	}




}
